d7d84fa3cf500b98a2015a51f754a526d2a1250f,clc/modules/wsstack/src/main/java/com/eucalyptus/ws/handlers/ServiceSinkHandler.java,ServiceSinkHandler,handleUpstream,#ChannelHandlerContext#ChannelEvent#,42
Before Change
Messaging.dispatch( "vm://RequestQueue", msg );
EucalyptusMessage reply = null;
reply = ReplyQueue.getReply( msg.getCorrelationId() );
LOG.info( EventRecord.create( this.getClass().getSimpleName(), msg.getUserId(), msg.getCorrelationId(), EventType.MSG_SERVICED, ( System.currentTimeMillis() - startTime ) ) );
if ( reply == null ) {
reply = new EucalyptusErrorMessageType( this.getClass().getSimpleName(), msg, "Received a NULL reply" );
}
After Change
requestLocal.set( ctx.getChannel( ), request );
EucalyptusMessage msg = ( EucalyptusMessage ) request.getMessage( );
LOG.info( EventRecord.create( this.getClass( ).getSimpleName( ), msg.getUserId( ), msg.getCorrelationId( ), EventType.MSG_RECEIVED, msg.getClass( ).getSimpleName( ) ) );
ReplyQueue.addReplyListener( msg.getCorrelationId( ), ctx );
Messaging.dispatch( "vm://RequestQueue", msg );
}
}